64550d09651d46d19fc7567aec5431005eb63bdd,providers/tcp/src/java/org/mule/providers/tcp/TcpMessageReceiver.java,TcpMessageReceiver,run,#,122
Before Change
try {
socket = serverSocket.accept();
TcpConnector connector = (TcpConnector) this.connector;
socket.setReceiveBufferSize(connector.getBufferSize());
socket.setSendBufferSize(connector.getBufferSize());
socket.setSoTimeout(connector.getReceiveTimeout());
logger.trace("Server socket Accepted on: " + serverSocket.getLocalPort());
} catch (java.io.InterruptedIOException iie) {
logger.debug("Interupted IO doing serverSocket.accept: " + iie.getMessage());
After Change
socket = serverSocket.accept();
TcpConnector connector = (TcpConnector) this.connector;
if (connector.getBufferSize() != UMOConnector.INT_VALUE_NOT_SET && socket.getReceiveBufferSize() != connector.getBufferSize()) {
socket.setReceiveBufferSize(connector.getBufferSize());
}
if (connector.getBufferSize() != UMOConnector.INT_VALUE_NOT_SET && socket.getSendBufferSize() != connector.getBufferSize()) {
socket.setSendBufferSize(connector.getBufferSize());
}
if (connector.getReceiveTimeout() != UMOConnector.INT_VALUE_NOT_SET && socket.getSoTimeout() != connector.getReceiveTimeout()) {
socket.setSoTimeout(connector.getReceiveTimeout());
}
socket.setTcpNoDelay(true);
if (logger.isTraceEnabled()) logger.trace("Server socket Accepted on: " + serverSocket.getLocalPort());